/*
 * 文件名：RealStreamUnit.java
 * 版权：亚信联创版权所有
 * 描述：TODO
 * 修改人：qiuyc
 * 修改时间：2014年11月2日
 * 修改内容：TODO
 */
package com.ailk.bigdata.etl.realstream.server.model;

import java.io.Serializable;
import java.util.List;

/**
 * @description TODO
 * @author [qiuyc]
 * @version [版本号,2014年11月2日]
 * @see [相关类/方法]
 * @since [产品/模块版本]
 */
public class RealStreamUnit implements Serializable
{
	private static final long serialVersionUID = -4801044791804665835L;
	private Long onlyUnitCode;// 唯一单元编码
	private String unitName;// 单元名称
	private String systemId;// 系统编码
	private String bussCode;// 业务编码
	/*
	 * 协议类型 1:aipr(亚信定义A口协议_云南) 2:SDTP 3;KAFKA 4:MQ ....
	 */
	private int protocolType;
	private int ifSendKakfa;
	private String kafkaId;
	private KafkaInfo kafkaInfo;
	private int partitionColumnIndex;// 发送kafka消息，定义分区字段
	private String acceptFormatId;// 输入解析格式编码
	private RealStreamFormat acceptFormat;
	private String sendFormatId;// 输出格式编码
	private RealStreamFormat sendFormat;
	private String hdfsId;
	private String metaTableId;// 表元数据编码
	private Table table;// 表
	private int ifCalc;// 是否计算处理 1.计算 2.非计算
	private int ifCreateFile;// 是否落地成文件 1.是 2.否
	private String createFileDir;
	private String createFileProfile;// 处理后文件名规则
	private int streamTransMode;// 数据流传输模式 1、主动 2、被动
	private int streamPassPort;// 被动模式端口
	private int afterCalc;// 计算后模式
	private int transWaitMinute;// 传输等待时间
	private String transWaitDir;// 超过等待时间放入文件夹
	private String transWaitFileProfile;// 等待文件名规则
	private List<SocketInfo> socketInfo;// 主动模式下socketInfo

	public Long getOnlyUnitCode()
	{
		return onlyUnitCode;
	}

	public void setOnlyUnitCode(Long onlyUnitCode)
	{
		this.onlyUnitCode = onlyUnitCode;
	}

	public String getUnitName()
	{
		return unitName;
	}

	public void setUnitName(String unitName)
	{
		this.unitName = unitName;
	}

	public String getSystemId()
	{
		return systemId;
	}

	public void setSystemId(String systemId)
	{
		this.systemId = systemId;
	}

	public String getBussCode()
	{
		return bussCode;
	}

	public void setBussCode(String bussCode)
	{
		this.bussCode = bussCode;
	}

	public int getProtocolType()
	{
		return protocolType;
	}

	public void setProtocolType(int protocolType)
	{
		this.protocolType = protocolType;
	}

	public int getIfSendKakfa()
	{
		return ifSendKakfa;
	}

	public void setIfSendKakfa(int ifSendKakfa)
	{
		this.ifSendKakfa = ifSendKakfa;
	}

	public String getKafkaId()
	{
		return kafkaId;
	}

	public void setKafkaId(String kafkaId)
	{
		this.kafkaId = kafkaId;
	}

	public KafkaInfo getKafkaInfo()
	{
		return kafkaInfo;
	}

	public void setKafkaInfo(KafkaInfo kafkaInfo)
	{
		this.kafkaInfo = kafkaInfo;
	}

	public int getPartitionColumnIndex()
	{
		return partitionColumnIndex;
	}

	public void setPartitionColumnIndex(int partitionColumnIndex)
	{
		this.partitionColumnIndex = partitionColumnIndex;
	}

	public String getAcceptFormatId()
	{
		return acceptFormatId;
	}

	public void setAcceptFormatId(String acceptFormatId)
	{
		this.acceptFormatId = acceptFormatId;
	}

	public RealStreamFormat getAcceptFormat()
	{
		return acceptFormat;
	}

	public void setAcceptFormat(RealStreamFormat acceptFormat)
	{
		this.acceptFormat = acceptFormat;
	}

	public String getSendFormatId()
	{
		return sendFormatId;
	}

	public void setSendFormatId(String sendFormatId)
	{
		this.sendFormatId = sendFormatId;
	}

	public RealStreamFormat getSendFormat()
	{
		return sendFormat;
	}

	public void setSendFormat(RealStreamFormat sendFormat)
	{
		this.sendFormat = sendFormat;
	}

	public String getHdfsId()
	{
		return hdfsId;
	}

	public void setHdfsId(String hdfsId)
	{
		this.hdfsId = hdfsId;
	}

	public String getMetaTableId()
	{
		return metaTableId;
	}

	public void setMetaTableId(String metaTableId)
	{
		this.metaTableId = metaTableId;
	}

	public Table getTable()
	{
		return table;
	}

	public void setTable(Table table)
	{
		this.table = table;
	}

	public int getIfCalc()
	{
		return ifCalc;
	}

	public void setIfCalc(int ifCalc)
	{
		this.ifCalc = ifCalc;
	}

	public int getIfCreateFile()
	{
		return ifCreateFile;
	}

	public void setIfCreateFile(int ifCreateFile)
	{
		this.ifCreateFile = ifCreateFile;
	}

	public String getCreateFileDir()
	{
		return createFileDir;
	}

	public void setCreateFileDir(String createFileDir)
	{
		this.createFileDir = createFileDir;
	}

	public String getCreateFileProfile()
	{
		return createFileProfile;
	}

	public void setCreateFileProfile(String createFileProfile)
	{
		this.createFileProfile = createFileProfile;
	}

	public int getStreamTransMode()
	{
		return streamTransMode;
	}

	public void setStreamTransMode(int streamTransMode)
	{
		this.streamTransMode = streamTransMode;
	}

	public int getStreamPassPort()
	{
		return streamPassPort;
	}

	public void setStreamPassPort(int streamPassPort)
	{
		this.streamPassPort = streamPassPort;
	}

	public int getAfterCalc()
	{
		return afterCalc;
	}

	public void setAfterCalc(int afterCalc)
	{
		this.afterCalc = afterCalc;
	}

	public int getTransWaitMinute()
	{
		return transWaitMinute;
	}

	public void setTransWaitMinute(int transWaitMinute)
	{
		this.transWaitMinute = transWaitMinute;
	}

	public String getTransWaitDir()
	{
		return transWaitDir;
	}

	public void setTransWaitDir(String transWaitDir)
	{
		this.transWaitDir = transWaitDir;
	}

	public String getTransWaitFileProfile()
	{
		return transWaitFileProfile;
	}

	public void setTransWaitFileProfile(String transWaitFileProfile)
	{
		this.transWaitFileProfile = transWaitFileProfile;
	}

	public List<SocketInfo> getSocketInfo()
	{
		return socketInfo;
	}

	public void setSocketInfo(List<SocketInfo> socketInfo)
	{
		this.socketInfo = socketInfo;
	}

}
